Node / meshtastic / Meshtastic-Android / files / core / network / src / jvmAndroidMain / kotlin / org / meshtastic / core / network / radio / TcpRadioTransport.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.network.radio

Tff7b72import T7ee787co.touchlab.kermit.Logger

Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope

Tff7b72import T7ee787org.meshtastic.core.common.util.handledLaunch

Tff7b72import T7ee787org.meshtastic.core.di.CoroutineDispatchers

Tff7b72import T7ee787org.meshtastic.core.network.transport.StreamFrameCodec

Tff7b72import T7ee787org.meshtastic.core.network.transport.TcpTransport

Tff7b72import T7ee787org.meshtastic.core.repository.RadioTransport

Tff7b72import T7ee787org.meshtastic.core.repository.RadioTransportCallback

Tff7b72import T7ee787kotlin.concurrent.Volatile

T8b949e/**

* TCP radio transport — thin adapter over the shared [TcpTransport] from `core:network`.

*

* Implements [RadioTransport] directly via composition over [TcpTransport], delegating send/receive to the transport

* and calling [RadioTransportCallback] for lifecycle events. This avoids the previous inheritance from

* [StreamTransport] which created a dead [StreamFrameCodec] and required overriding `sendBytes` as a no-op.

*/

Tff7b72open Tff7b72class T56d364TcpRadioTransportTb4b4b4(

Tff7b72private Tff7b72val Te6edf3callbackTb4b4b4: Te6edf3RadioTransportCallbackTb4b4b4,

Tff7b72private Tff7b72val Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4,

Tff7b72private Tff7b72val Te6edf3dispatchersTb4b4b4: Te6edf3CoroutineDispatchersTb4b4b4,

Tff7b72private Tff7b72val Te6edf3addressTb4b4b4: Tffa657StringTb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3RadioTransport Tb4b4b4{

Tff7b72companion Tff7b72object Tb4b4b4{

Tff7b72const Tff7b72val Te6edf3SERVICE_PORT Tff7b72= Te6edf3StreamFrameCodecTb4b4b4.Te6edf3DEFAULT_TCP_PORT

Tb4b4b4}

T8b949e/** Guards against a double [RadioTransportCallback.onDisconnect] when [close] triggers [TcpTransport.stop]. */

Tf0883e@Volatile Tff7b72private Tff7b72var Te6edf3closing Tff7b72= Tff7b72false

Tff7b72private Tff7b72val Te6edf3transport Tff7b72=

Te6edf3TcpTransportTb4b4b4(

Te6edf3dispatchers Tff7b72= Te6edf3dispatchersTb4b4b4,

Te6edf3scope Tff7b72= Te6edf3scopeTb4b4b4,

Te6edf3listener Tff7b72=

Tff7b72object Tb4b4b4: T56d364TcpTransportTb4b4b4.Te6edf3Listener Tb4b4b4{

Tff7b72override Tff7b72fun Td2a8ffonConnectedTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3callbackTb4b4b4.Te6edf3onConnectTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffonDisconnectedTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3closingTb4b4b4) Tff7b72return T8b949e// close() will fire the permanent disconnect itself

T8b949e// TCP disconnects are transient (not permanent) — the transport will auto-reconnect.

Te6edf3callbackTb4b4b4.Te6edf3onDisconnectTb4b4b4(Te6edf3isPermanent Tff7b72= Tff7b72falseTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffonPacketReceivedTb4b4b4(Te6edf3bytesTb4b4b4: Te6edf3ByteArrayTb4b4b4) Tb4b4b4{

Te6edf3callbackTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3bytesTb4b4b4)

Tb4b4b4}

Tb4b4b4}Tb4b4b4,

Te6edf3logTag Tff7b72= Ta5d6ff"Ta5d6ffTcpRadioTransport[Tffd700$Te6edf3addressTa5d6ff]Ta5d6ff"Tb4b4b4,

Tb4b4b4)

Tff7b72override Tff7b72fun Td2a8ffstartTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Te6edf3addressTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffcloseTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ff[Tffd700$Te6edf3addressTa5d6ff] Closing TCP transportTa5d6ff" Tb4b4b4}

Te6edf3closing Tff7b72= Tff7b72true

Te6edf3transportTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4)

T8b949e// Do NOT emit onDisconnect(isPermanent = true) here. The explicit-disconnect signal is the

T8b949e// service layer's responsibility (SharedRadioInterfaceService.stopTransportLocked); emitting

T8b949e// it from close() caused a double-disconnect and prevented the auto-reconnect loop from

T8b949e// owning its own lifecycle. The `closing` guard above suppresses the listener's transient

T8b949e// disconnect during teardown.

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffkeepAliveTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ff[Tffd700$Te6edf3addressTa5d6ff] TCP keepAliveTa5d6ff" Tb4b4b4}

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3sendHeartbeatTb4b4b4(Tb4b4b4) Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffhandleSendToRadioTb4b4b4(Te6edf3pTb4b4b4: Te6edf3ByteArrayTb4b4b4) Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{ Te6edf3transportTb4b4b4.Te6edf3sendPacketTb4b4b4(Te6edf3pTb4b4b4) Tb4b4b4}

Tb4b4b4}

Tb4b4b4}